welo git mirrors - /page/commit.mu

Micron Document

welo git mirrors

Node / public / rns-proxy / commits / 5e44a14

Commit 5e44a149685bb96abebea48cc9495cf71cdb80b5

🗀 Browse tree at this commit

Parents : 0fc62d5

Author : welo | main nixos computer <empty@empty.com>

Date : 2026-07-11T19:41:33+01:00

extra debug printing to figure out bug that occurs why out of sync bug happens

Changes

1 files changed, 4 insertions(+), 2 deletions(-)

M src/mux.rs +4 -2

Diff

diff --git a/src/mux.rs b/src/mux.rs

index 4ce3fd8..87877ad 100644

--- a/src/mux.rs

+++ b/src/mux.rs

@@ -169,6 +169,7 @@ impl MuxHandle {

let mut buf = self.inner.recv_buf.lock().await;

buf.extend_from_slice(data);

// info!("buf: {:?}", buf);

+ let buf_clone = buf.clone();

let mut frames = Vec::new();

loop {

@@ -194,8 +195,9 @@ impl MuxHandle {

DecodingFailed => {

// something has gone really wrong, just clear the buffer and hope things

// work out.

- error!("decoding failed for a packet, something really bad is happening {:?}",buf);

- error!("ignoring packet buffer and hoping that will fix it");

+ error!("decoding failed for a packet, something really bad is happening buf: {:?} data: {:?}",buf, data);

+ error!("original buf {:?}", buf_clone);

+ error!("abort to avoid corrupting the stream:");

assert!(false);

buf.drain(..);

break;